package com.sdy.mq.base;

import org.apache.rocketmq.common.message.MessageExt;

public abstract class BaseMessageConsumer {
    protected abstract boolean consume(MessageExt message);
}